package com.stream.producter;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.cloud.stream.annotation.Output;
import org.springframework.messaging.MessageChannel;
import org.springframework.messaging.SubscribableChannel;
import org.springframework.stereotype.Component;


@Component
public interface ProductChannel {

    //消费者生产者通道
    String outChannel = "proConsumeChannel";

    // 反馈通道
    String inputChannel = "feedBackChannel";


    @Output(value = ProductChannel.outChannel)
    public MessageChannel outChannel();

    @Input(value = ProductChannel.inputChannel)
    public SubscribableChannel inputChannel();

}
